a0786f0d4eadfb2c84805915ca98b11a4c117429,src/main/java/water/exec/ASTRApply.java,RemoteExec,compute2,#,424
Before Change
System.out.println("ddply on group "+Arrays.toString(_ds)+" rows="+_fr.numRows()+", env="+_env+", op="+_op);
// Clone a private copy of the environment for local execution
_env = _env.capture(true);
_env.push(_op);
_env.push(_fr);
After Change
@Override public void compute2() {
Env shared_env = UKV.get(_envkey);
// Clone a private copy of the environment for local execution
Env env = shared_env.capture(true);
ASTOp op = env.fcn(-1);
System.out.println("ddply on group "+Arrays.toString(_ds)+" rows="+_fr.numRows()+", env="+env+", op="+op);